# -*- coding: utf-8 -*-

from celery import Celery

from lib.kafka_producer import KProducer

app = Celery('DH')
app.config_from_object('celeryapp.celeryconfig')